//package com.cenntro.oss.mq;
//
//import java.util.List;
//
//import org.apache.rocketmq.common.message.MessageExt;
//import org.springframework.stereotype.Service;
//
//import com.cenntro.common.mq.TopicEnum;
//import com.cenntro.common.mq.annotation.MQConsumeService;
//import com.cenntro.common.mq.consumer.processor.AbstractMQMsgProcessor;
//import com.cenntro.common.mq.consumer.processor.MQConsumeResult;
//@Service
//@MQConsumeService(topic=TopicEnum.DemoTopic,tags={"*"})
//public class MQMsgProcessor extends AbstractMQMsgProcessor{
//
//	@Override
//	protected MQConsumeResult consumeMessage(String tag, List<String> keys, MessageExt messageExt) {
//		// TODO Auto-generated method stub
//		return null;
//	}
//}
